//package com.jiegui.modules.wechat.monitor;
//
//import com.alibaba.fastjson.JSON;
//import com.alibaba.fastjson.JSONObject;
//import com.jiegui.common.model.MessageSendModel;
//import com.jiegui.framework.utils.WechatUtils;
//import com.jiegui.sms.model.SendSmsModel;
//import com.jiegui.sms.service.SmsInterfaceRequestService;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.Resource;
//
///**
// * @description:
// * @author: wuqicheng
// * @time: 07/12/2021 3:04 PM
// */
//@Slf4j
//@Component
//public class KafkaMonitor {
//    @Resource
//    SmsInterfaceRequestService smsInterfaceRequestService;
//
//    @KafkaListener(topics = "KAFKATEST",containerFactory = "kafkaListenerContainerFactory")
//    public void receiver(String record) {
//        System.out.println("收到kafka消息");
//    }
//
//
//    /**
//     * 短信kafka监听
//     * @param message json消息
//     */
//    @KafkaListener(topics = {"SEND_SMS_TOPIC"})
//    public void sendSms(String message) {
//        try {
//            SendSmsModel sendSmsDto = JSON.parseObject(message, SendSmsModel.class);
//            smsInterfaceRequestService.sendSms(sendSmsDto);
//        } catch (Exception e) {
//            log.error("Kafka发送短信异常：[{}]", e.getMessage());
//        }
//    }
//
//    /**
//     * 短信kafka监听
//     * @param message json消息
//     */
//    @KafkaListener(topics = {"MP_TEMPLATE_MSG"})
//    public void SendTemplateMsg(String message) {
//        log.info("公众号模板消息发生开始");
//        //   log.info("公众号模板消息接收到的数据：message={}", Template);
//        MessageSendModel model = new MessageSendModel();
//        try {
//            JSONObject js = JSONObject.parseObject(message);
//            String oldId="gh_c9a232fd7ea0";
////
////            WechatNewstemplateEntity one = wechatNewstemplateService.getOne(new QueryWrapper<WechatNewstemplateEntity>()
////                    .eq("jwid", oldId)
////                    .eq("template_name", js.getString("templateId"))
////                    .eq("del_flag", 0));
//           // if (one!=null){
//                //TmessageSendVO tmessageSendVO = JsonUtils.parseObject(Template, TmessageSendVO.class);
//                model.setData(js.getString("data"));
//                model.setTouser(js.getString("touser"));
//               // model.setTouser(js.getString(""));
//                model.setTemplateId(js.getString("templateId"));
//                model.setJwid(oldId);
//                model.setType(js.getString("type"));
//                WechatUtils.SendTemplateMsg(model);
//           // }
//        } catch (Exception e) {
//            e.printStackTrace();
//            log.error("-------------模板消息：{},模板消息出现异常，异常原因：{}", model, e.getMessage());
//        }
//    }
//
//}
